<template>
  <div class="jobIndex">
    <BasicContainer>
      <FyCurd
        ref="crud"
        v-model="form"
        :page.sync="page"
        :data="tableData"
        :table-loading="tableLoading"
        :option="tableOption"
        @on-load="getList"
        @row-save="save"
        @row-update="update"
        @refresh-change="refreshChange"
        @size-change="sizeChange"
        @current-change="currentChange"
        @search-change="handleFilter"
        @search-reset="handleSearchReset">
        <template #jobStatus="scope">
          <div v-if="scope.row.jobStatus === '1'">
            <ElTag type="info">
              {{ getDicNameJobStatus(scope.row.jobStatus) }}
            </ElTag>
          </div>
          <div v-else-if="scope.row.jobStatus === '2'">
            <ElTag type="success">
              {{ getDicNameJobStatus(scope.row.jobStatus) }}
            </ElTag>
          </div>
          <div v-else-if="scope.row.jobStatus === '3'">
            <ElTag type="danger">
              {{ getDicNameJobStatus(scope.row.jobStatus) }}
            </ElTag>
          </div>
        </template>
        <template #jobExecuteStatus="scope">
          <div v-if="scope.row.jobExecuteStatus === '0'">
            <ElTag type="success">
              {{ getDicNameJobExecuteStatus(scope.row.jobExecuteStatus) }}
            </ElTag>
          </div>
          <div v-else>
            <ElTag type="danger">
              {{ getDicNameJobExecuteStatus(scope.row.jobExecuteStatus) }}
            </ElTag>
          </div>
        </template>
        <template #cronExpressionForm>
          <div class="cron">
            <ElPopover v-model="cronPopover">
              <VueCron i18n="cn" @change="changeCron" @close="cronPopover = false" />
              <template #reference>
                <ElInput v-model="form.cronExpression" placeholder="请输入定时策略" @click="cronPopover = true" />
              </template>
            </ElPopover>
          </div>
        </template>
        <template #menuLeft>
          <ElButton v-if="permissions.job_sys_job_add" type="primary" @click="handleAdd"> 新建任务 </ElButton>
          <ElTooltip content="暂停全部运行状态的定时任务" placement="top">
            <ElButton v-if="permissions.job_sys_job_shutdown_job" type="warning" @click="shutdownJobs">
              暂停全部任务
            </ElButton>
          </ElTooltip>
          <ElTooltip content="启动全部暂停状态的定时任务" placement="top">
            <ElButton v-if="permissions.job_sys_job_start_job" type="success" @click="startJobs">
              启动全部任务
            </ElButton>
          </ElTooltip>
          <ElTooltip content="谨慎使用" placement="top">
            <ElButton v-if="permissions.job_sys_job_refresh_job" type="danger" @click="refreshJobs">
              重置全部任务
            </ElButton>
          </ElTooltip>
        </template>
        <template #menu="scope">
          <ElButton type="text" icon="el-icon-info" @click="handleJobLog(scope.row)"> 日志 </ElButton>
          <ElButton
            v-if="permissions.job_sys_job_start_job"
            type="text"
            icon="el-icon-caret-right"
            @click="handleStartJob(scope.row)">
            启动
          </ElButton>

          <ElButton
            v-if="permissions.job_sys_job_shutdown_job"
            type="text"
            icon="el-icon-error"
            @click="handleShutDownJob(scope.row)">
            暂停
          </ElButton>
          <ElButton
            v-if="permissions.job_sys_job_edit"
            type="text"
            icon="el-icon-edit"
            @click="handleUpdate(scope.row, scope.index)">
            修改
          </ElButton>
          <ElButton
            v-if="permissions.job_sys_job_run_job"
            type="text"
            icon="el-icon-s-promotion"
            @click="handleRunJob(scope.row)">
            执行
          </ElButton>
          <ElButton
            v-if="permissions.job_sys_job_del"
            type="text"
            icon="el-icon-delete"
            @click="handleDelete(scope.row, scope.index)">
            删除
          </ElButton>
        </template>
      </FyCurd>
    </BasicContainer>
    <JobLog v-if="dialogFormVisible" :row="currentRow" :visible.sync="dialogFormVisible" />
  </div>
</template>

<script>
  import {
    addObj,
    delObj,
    fetchList,
    isValidTaskName,
    putObj,
    refreshJobsRa,
    runJobRa,
    shutDownJobRa,
    shutdownJobsRa,
    startJobRa,
    startJobsRa
  } from '@/api/daemon/sys-job'
  import { tableOption } from '@/const/crud/daemon/sys-job'
  import { mapState } from 'vuex'
  import JobLog from './job-log'
  import { getDictData } from '@/util/dictionary'

  export default {
    name: 'JobIndex',
    components: { JobLog },
    data() {
      return {
        form: {},
        cronPopover: false,
        queryParams: {}, // 全局检索条件
        tableData: [],
        dialogFormVisible: false,
        page: {
          total: 0, // 总页数
          currentPage: 1, // 当前页数
          pageSize: 10 // 每页显示多少条,
        },
        tableLoading: false,
        tableOption,
        JobExecuteStatusDicCache: [],
        JobStatusDicCache: [],
        currentRow: {}
      }
    },
    computed: {
      ...mapState('user', ['permissions'])
    },
    mounted: function () {
      this.getDicJobExecuteStatusCache('job_execute_status') // 获取定时任务运行时状态
      this.getDicJobStatusCache('job_status') // 获取定时任务状态
    },
    methods: {
      changeCron(val) {
        this.form.cronExpression = val
      },
      /**
       * 定时任务分页查询
       */
      getList() {
        this.tableLoading = true
        fetchList(
          Object.assign(
            {
              descs: 'create_time',
              current: this.page.currentPage,
              size: this.page.pageSize
            },
            this.queryParams
          )
        ).then(response => {
          this.tableData = response.data.data.records
          this.page.total = response.data.data.total
          this.tableLoading = false
        })
      },
      /**
       * 清除全局检索条件
       */
      handleSearchReset() {
        this.queryParams = {}
      },
      /**
       * 定时任务检索查询分页查询
       */
      handleFilter(params, done) {
        this.queryParams = params
        this.page.currentPage = 1
        this.getList(this.page)
        done()
      },
      /**
       * 启动定时任务
       */
      handleStartJob(row) {
        const jobStatus = row.jobStatus
        if (jobStatus === '1' || jobStatus === '3') {
          this.$confirm(`即将发布或启动(任务名称:${row.jobName}), 是否继续?`, '提示', {
            confirmButtonText: '确定',
            cancelButtonText: '取消',
            type: 'warning'
          }).then(() => {
            startJobRa(row.jobId)
              .then(response => {
                const code = response.data.code
                if (code === 0) {
                  this.$notify({
                    title: '成功',
                    message: '启动成功',
                    type: 'success'
                  })
                  this.refreshChange()
                }
              })
              .catch(() => {
                this.$notify.error({
                  title: '错误',
                  message: '启动失败'
                })
              })
          })
        } else {
          this.$notify.error({
            title: '错误',
            message: '定时任务已运行'
          })
        }
      },
      /**
       * 执行定时任务
       */
      handleRunJob(row) {
        this.$confirm(`立刻执行一次任务(任务名称:${row.jobName}), 是否继续?`, '提示', {
          confirmButtonText: '确定',
          cancelButtonText: '取消',
          type: 'warning'
        }).then(() => {
          runJobRa(row.jobId)
            .then(response => {
              const code = response.data.code
              if (code === 0) {
                this.$notify({
                  title: '成功',
                  message: '执行成功',
                  type: 'success'
                })
                this.refreshChange()
              }
            })
            .catch(() => {
              this.$notify.error({
                title: '错误',
                message: '执行失败'
              })
            })
        })
      },
      handleAdd() {
        this.$refs.crud.rowAdd()
      },
      handleUpdate(row, index) {
        const jobStatus = row.jobStatus
        if (jobStatus === '1' || jobStatus === '3') {
          this.$refs.crud.rowEdit(row, index)
        } else {
          this.$notify.error({
            title: '错误',
            message: '运行中定时任务不可修改，请先暂停后操作'
          })
        }
      },
      /**
       * 暂停定时任务
       */
      handleShutDownJob(row) {
        const jobStatus = row.jobStatus
        if (jobStatus === '2') {
          this.$confirm(`即将暂停(任务名称:${row.jobName}), 是否继续?`, '提示', {
            confirmButtonText: '确定',
            cancelButtonText: '取消',
            type: 'warning'
          }).then(() => {
            shutDownJobRa(row.jobId)
              .then(response => {
                const code = response.data.code
                if (code === 0) {
                  this.getList(this.page)
                  this.$notify({
                    title: '成功',
                    message: '暂停成功',
                    type: 'success'
                  })
                }
                this.refreshChange()
              })
              .catch(() => {
                this.$notify.error({
                  title: '错误',
                  message: '暂停失败'
                })
              })
          })
        } else {
          this.$notify.error({
            title: '错误',
            message: '已暂停，不要重复操作'
          })
        }
      },
      /**
       * 刷新回调
       */
      refreshChange() {
        this.getList(this.page)
      },
      sizeChange(pageSize) {
        this.page.pageSize = pageSize
      },
      currentChange(current) {
        this.page.currentPage = current
      },
      shutdownJobs() {
        this.$confirm('即将暂停全部运行中定时任务, 是否继续?', '提示', {
          confirmButtonText: '确定',
          cancelButtonText: '取消',
          type: 'warning'
        }).then(() => {
          shutdownJobsRa()
            .then(response => {
              const code = response.data.code
              const data = response.data.data
              if (code === 0) {
                this.getList(this.page)
                this.$notify.success(data)
              } else {
                this.$notify.error('暂停失败')
              }
            })
            .catch(() => {
              this.$notify.error('暂停失败')
            })
        })
      },
      /**
       * 启动全部暂停定时任务
       */
      startJobs() {
        this.$confirm('即将启动全部暂定中定时任务, 是否继续?', '提示', {
          confirmButtonText: '确定',
          cancelButtonText: '取消',
          type: 'warning'
        }).then(() => {
          startJobsRa()
            .then(response => {
              const code = response.data.code
              if (code === 0) {
                this.getList(this.page)
                this.$notify.success('启动成功')
              } else {
                this.$notify.error('启动失败')
              }
            })
            .catch(() => {
              this.$notify.error('启动失败')
            })
        })
      },
      /**
       * 刷新定时任务
       */
      refreshJobs() {
        this.$confirm('即将刷新全部定时任务, 是否继续?', '提示', {
          confirmButtonText: '确定',
          cancelButtonText: '取消',
          type: 'warning'
        }).then(() => {
          refreshJobsRa()
            .then(response => {
              const code = response.data.code
              if (code === 0) {
                this.getList(this.page)
                this.$notify.success('重置成功')
              } else {
                this.$notify.error('重置失败')
              }
            })
            .catch(() => {
              this.$notify.error('重置失败')
            })
        })
      },
      /**
       * 新增定时任务持久化处理
       */
      save(row, done, loading) {
        isValidTaskName({
          jobName: row.jobName,
          jobGroup: row.jobGroup
        })
          .then(response => {
            const result = response.data.code
            if (result !== 0) {
              this.$notify.error('任务名称与任务组重复，请确认后重新添加')
            } else {
              addObj(row)
                .then(() => {
                  this.$notify.success('创建成功')
                  this.getList(this.page)
                })
                .catch(() => {
                  loading()
                })
            }
            done()
          })
          .catch(() => {
            loading()
          })
      },
      /**
       * 更新定时任务持久化处理
       */
      update(row, index, done, loading) {
        putObj(row)
          .then(() => {
            this.getList(this.page)
            done()
            this.$notify.success('修改成功')
          })
          .catch(() => {
            loading()
          })
      },
      /**
       * 删除定时任务持久化处理
       */
      handleDelete(row) {
        const jobStatus = row.jobStatus
        if (jobStatus === '1' || jobStatus === '3') {
          this.$confirm(`是否确认删除(任务名称:${row.jobName}), 是否继续?删除后不可恢复`, '警告', {
            confirmButtonText: '确定',
            cancelButtonText: '取消',
            type: 'warning'
          })
            .then(() => {
              return delObj(row.jobId)
            })
            .then(() => {
              this.getList(this.page)
              this.$notify.success('删除成功')
            })
            .catch(() => {})
        } else {
          this.$notify.error('运行中定时任务不可删除，请先暂停后操作')
        }
      },
      async handleJobLog(row) {
        this.currentRow = row
        this.dialogFormVisible = true
      },
      /**
       * 获取字典显示名称并缓存
       */
      getDicJobExecuteStatusCache(type) {
        getDictData(type).then(response => {
          this.JobExecuteStatusDicCache = response
        })
      },
      /**
       * 获取字典显示名称并缓存
       */
      getDicJobStatusCache(type) {
        getDictData(type).then(response => {
          this.JobStatusDicCache = response
        })
      },
      /**
       * 获取字典定时任务执行状态字典值显示名称
       */
      getDicNameJobExecuteStatus(value) {
        let re = ''
        this.JobExecuteStatusDicCache.forEach(obj => {
          if (obj.value === value) {
            re = obj.label
          }
        })
        return re
      },
      /**
       * 获取字典定时任务状态字典值显示名称
       */
      getDicNameJobStatus(value) {
        let re = ''
        this.JobStatusDicCache.forEach(obj => {
          if (obj.value === value) {
            re = obj.label
          }
        })
        return re
      }
    }
  }
</script>
